package com.dongecloud.stream;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;


@EnableBinding(Sink.class)
public class MsgReceiver {
   private static final Logger logger = LoggerFactory.getLogger(MsgReceiver.class);

   @StreamListener(Sink.INPUT)
   public  void receive(Object obj){
       logger.info("receive:"+ obj);
   }
}
